package com.xian.scala.batch

import org.apache.flink.api.scala.ExecutionEnvironment

/**
 * 从文件读取数据
 */
object ReadFileData {
  def main(args: Array[String]): Unit = {
    val env = ExecutionEnvironment.getExecutionEnvironment
    val lines = env.readTextFile("e:/test/wc.txt")
    lines.print()

  }
}
